'''
Created on 2017年9月12日

@author: zhangyanfeng
'''

from pyspark import SparkContext, SparkConf, rdd

sc = SparkContext( 'local', 'pyspark')
# lines = sc.textFile("hdfs://192.168.13.131:9000/resources/README.md")
lines = sc.textFile("hdfs://192.168.13.131:9000/resources/score.txt")
print(lines.collect())

#filter data 
